let fs = require('fs')

let rs = fs.createReadStream('test.txt', {
  highWaterMark:4
})

let ws = fs.createWriteStream('test1.txt',{
  highWaterMark:1
})

// let flag = true

// rs.on('data', (chunk)=>{
//   flag = ws.write(chunk,()=>{
//     console.log('写完了')
//   })
//   if(!flag){
//     // 暂停
//     rs.pause()
//   }
// })
// ws.on('drain', ()=>{
//   // 恢复流动
//   rs.resume()
// })
// // 写完了
// // 写完了
// // 写完了
// // 四个汉字12字节，每次流动4字节，所以响应了3次。

rs.pipe(ws)
